from app.celery import app as celery_app

# 创建任务函数
@celery_app.task
def my_task1():
    """具体要执行的业务逻辑，如发生邮件、短信等"""
    print("任务函数(my_task1)正在执行....")

@celery_app.task
def my_task2():
    print("任务函数(my_task2)正在执行....")

@celery_app.task
def my_task3():
    print("任务函数(my_task3)正在执行....")
    return "OK"


# 在终端启动Django服务
# 在终端启动Celery worker：celery -A celery_demo.tasks worker -l info -P eventlet
# 如果需要监控，可使用flower模块，安装并在终端执行：flower -A celery_demo.tasks --port-5555
# 在浏览器打开http://localhost:5555/，即可监控celery服务状态
# 正常使用时，导包，在接口里实现视图，使用my_task1.delay(), 或者apply_async()、或者send_task()
if __name__ == '__main__':
    my_task1.delay()
    my_task2.delay()
    my_task3.delay()
